package com.wang.wx.constants;


import com.wang.wx.entity.EmailUser;
import com.wang.wx.entity.LyUser;
import com.wang.wx.entity.TwitterUser;
import com.wang.wx.entity.WxUser;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicBoolean;

public class BatchConstants {

    public static final BlockingQueue<WxUser> WX_QUEUE = new LinkedBlockingQueue<>(20000);
    public static final BlockingQueue<LyUser> LY_QUEUE = new LinkedBlockingQueue<>(20000);
    public static final BlockingQueue<EmailUser> EMAIL_QUEUE = new LinkedBlockingQueue<>(20000);
    public static final BlockingQueue<TwitterUser> TWITTER_QUEUE = new LinkedBlockingQueue<>(20000);
    public static final AtomicBoolean WX_SIGNAL_COMPLETION = new AtomicBoolean(false);
    public static final AtomicBoolean LY_SIGNAL_COMPLETION = new AtomicBoolean(false);
    public static final AtomicBoolean EMAIL_SIGNAL_COMPLETION = new AtomicBoolean(false);
    public static final AtomicBoolean TWITTER_SIGNAL_COMPLETION = new AtomicBoolean(false);
}